746f320a3ae5cdb8fcec8db095ced7a5ffed3127,rxnetty-examples/src/main/java/io/reactivex/netty/examples/http/ws/echo/WebSocketEchoServer.java,WebSocketEchoServer,main,#String[]#,34
Before Change
HttpServer<ByteBuf, ByteBuf> server;
/*Starts a new HTTP server on an ephemeral port.*/
server = HttpServer.newServer()
/*Starts the server with a request handler.*/
.start((req, resp) -> {
/*If WebSocket upgrade is requested, then accept the request with an echo handler.*/
if (req.isWebSocketUpgradeRequested()) {
After Change
HttpServer<ByteBuf, ByteBuf> server;
/*Starts a new HTTP server on an ephemeral port.*/
server = HttpServer.newServer()
.enableWireLogging(LogLevel.DEBUG)
/*Starts the server with a request handler.*/
.start((req, resp) -> {
/*If WebSocket upgrade is requested, then accept the request with an echo handler.*/
if (req.isWebSocketUpgradeRequested()) {